package com.zhang.flink.utils;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;


/**
 * @title:
 * @author: zhang
 * @date: 2022/2/26 16:40
 */
public class RedisUtils {
    private static JedisPool jedisPool = null;
    public static Jedis getJedis(){
        if (jedisPool==null){
            JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
            jedisPoolConfig.setMaxTotal(10); //设置最大连接数
            jedisPoolConfig.setMaxIdle(5); //设置最大空闲连接数
            jedisPoolConfig.setMinIdle(3); //设置最小空闲连接数
            jedisPoolConfig.setBlockWhenExhausted(true); //连接耗尽是否等待
            jedisPoolConfig.setMaxWaitMillis(5000); //等待时间
            jedisPoolConfig.setTestOnBorrow(true); //取连接进行测试
            JedisPool jedisPool = new JedisPool(jedisPoolConfig, "hadoop102", 6379);
            return jedisPool.getResource();
        }else {
            return jedisPool.getResource();
        }
    }
}
